package com.central.wx.mq

import org.springframework.cloud.stream.annotation.EnableBinding
import org.springframework.cloud.stream.annotation.Input
import org.springframework.messaging.SubscribableChannel

/**
 * @author  fly
 * @date  2021/6/2 14:58
 * @version 1.0
 */

const val REWARD_INPUT = "reward_input"
const val COMMENT_INPUT = "comment_input"
const val NEW_GOOD_INPUT = "new_good_input"

@EnableBinding(WxSink::class)
open class WxMqConfig

interface WxSink{

    @Input(REWARD_INPUT)
    fun rewardSink(): SubscribableChannel

    @Input(COMMENT_INPUT)
    fun commentSink(): SubscribableChannel

    @Input(NEW_GOOD_INPUT)
    fun newGoodSink(): SubscribableChannel
}